package com.dsp.week12.service;

import io.github.majusko.pulsar.PulsarMessage;
import io.github.majusko.pulsar.annotation.PulsarConsumer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

@Slf4j
@Service
public class MyConsumer {

    @PulsarConsumer(topic = "${my-topic.test}", clazz = String.class)
    public void consumeString(PulsarMessage<String> pulsarMessage) {
        log.info("PulsarConsumer: String.class ---> {}", pulsarMessage.getValue());
    }
}
